package com.metaq.consumer;


import java.util.Map;

import com.taobao.metamorphosis.Message;
import com.taobao.metamorphosis.client.extension.spring.DefaultMessageListener;
import com.taobao.metamorphosis.client.extension.spring.MetaqMessage;
/**
 * 接收
 * @author litianyi
 *
 * 2015年10月21日
 */
public class PushListener extends DefaultMessageListener<Message> {
	
	
	@Override
	public void onReceiveMessages(MetaqMessage<Message> msg) {
		System.out.println("消息接收...");
		if(msg.getBody() == null){
			throw new IllegalArgumentException("PushMessage is null.");
		}
		if(msg.getBody() instanceof Map){
			Map body = (Map)msg.getBody();
			System.out.println("接收端信息:"+body.get("name"));
		}
		
		
			
	}

}
